package com.chj.comp.common.mqadmin.service;

import com.chj.comp.common.core.util.Result;
import com.chj.comp.common.core.entity.MqMessageInfo;
import com.baomidou.mybatisplus.extension.service.IService;

import java.util.List;

/**
 * <p>
 * rabbitmq消息信息表 服务类
 * </p>
 *
 * @author cuihui
 * @since 2022-06-14
 */
public interface IMqMessageInfoService extends IService<MqMessageInfo> {

    Result addMqMessageInfo(MqMessageInfo mqMessageInfo);
    Result updateMqMessageStatus(String messageId, String status);
    Result<Integer> judgeMqMessageStatus(String messageId);
    List<MqMessageInfo> getErrorMqMessageList();
    Result addMqMessageSendNum(String messageId);

}
